package com.example.cloud.service;

import org.springframework.cloud.stream.annotation.Output;
import org.springframework.cloud.stream.messaging.Sink;
import org.springframework.messaging.MessageChannel;

/**
 * 发送消息。
 *
 * @author tongyufu
 */
public interface SinkSender {

    /**
     * Output注解参数值是kafka topic名称，方法名建议与topic相同
     *
     * @return channel
     */
    @Output(Sink.INPUT)
    MessageChannel input();

}
